package cn.crsc.openlookeng.reposity;

import cn.crsc.openlookeng.adhoc.jdbc.EngineType;
import cn.crsc.openlookeng.annotation.Catalog;
import cn.crsc.openlookeng.annotation.Query;
import cn.crsc.openlookeng.annotation.Schema;

import java.util.List;
import java.util.Map;

public interface KafkaRepo {

    @Catalog(EngineType.KAFKA)
    @Schema("default")
    @Query("select * from mytest limit 10")
    Map findAll();
}
